package com.dxf.redis.pubsub;

import com.dxf.redis.pubsub.CustomJedisPubSub;
import com.dxf.redis.pubsub.CustomPublishJedis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

public class JedisMain {
    public static void main(String[] args) {

        Jedis jedis = new Jedis("192.168.10.113", 6379);

        jedis.select(2);

       /* jedis.set("key_st","student");
        String st = jedis.get("key_st");
        System.out.println(st);*/

        CustomJedisPubSub customJedisPubSub = new CustomJedisPubSub();

        jedis.subscribe(customJedisPubSub,"test");
        //jedis.publish("test","helloworld");


        CustomPublishJedis test = new CustomPublishJedis("test", jedis);
        test.publish("hello word!!!!");


        jedis.close();
    }
}
